# -*- coding: utf-8 -*-
from airflow.operators.python import PythonOperator
from .dm_free_route_push_data_success import main
from jms.dm.route.dm_free_route_sign_dt import jms_dm__dm_free_route_sign_dt

jms_dm__dm_free_route_sign_success = PythonOperator(
    task_id='jms_dm__dm_free_route_sign_success',
    email='zhangqinglin@jtexpress.com',
    pool='unlimited_pool',
    python_callable=main,
    op_args=['{{ execution_date | cst_ds }}', '{{ var.json.mysq_sync_status2kafka }}'],
)


jms_dm__dm_free_route_sign_success << [
    jms_dm__dm_free_route_sign_dt
]